#include "sql_operation.h"
#include "database_thread.h"
#include "query_callback.h"
#include "query_result.h"

namespace engine
{
	void SqlStatement::execute(DatabaseThread* db)
	{
		db->execute(mSql);
	}

	void SqlQuery::execute(DatabaseThread* db)
	{
		QueryResultSet* resultSet = db->query(mSql);
		mCallback->setResultSet(resultSet);

		db->pushResult(mCallback);
	}
}

